/**
 * 讯飞API服务
 * 直接调用后台MCP接口
 */
import { getReadClient } from '../../../Urls/AxiosHelper'

// 使用Team管理服务器（索引1），与其他Scheduling模块保持一致
const Read = getReadClient(1)

// 简化的聊天请求接口
export interface ChatRequest {
  message: string
}

// 简化的聊天响应接口
export interface ChatResponse {
  code: number
  message: string
  data: any
}

/**
 * 发送聊天消息到后台MCP接口
 * @param message 用户消息
 * @returns Promise<ChatResponse>
 */
export async function sendChatMessage(message: string): Promise<ChatResponse> {
  try {
    console.log('发送消息到MCP接口:', message)
    const response = await Read.post<ChatResponse>('schedread/api/Xunfei/chat', {
      message: message
    })
    console.log('MCP接口响应:', response.data)
    return response.data
  } catch (error: any) {
    console.error('讯飞聊天API调用失败:', error)
    console.error('错误详情:', error.response?.data)
    throw new Error(error?.response?.data?.message || error?.message || '聊天服务暂时不可用')
  }
}

/**
 * 检查讯飞服务健康状态
 * @returns Promise<any>
 */
export async function checkXunfeiHealth(): Promise<any> {
  try {
    const response = await Read.get('schedread/api/Xunfei/health')
    return response.data
  } catch (error: any) {
    console.error('讯飞健康检查失败:', error)
    throw new Error(error?.response?.data?.message || error?.message || '服务连接失败')
  }
}
